package common.mq.basic.service;

import java.util.Map;

import common.mq.po.Message;

public interface MessageService {
	
	/**
	 * 获取消息下次执行时间
	 * @param m
	 * @return
	 */
	public int gainNextTime(Message m);
	
	/**
	 * 检查消息是否符合格式
	 * @param m
	 * @return
	 */
	public boolean checkMessageFormat(Message m);
	
	/**
	 * 拷贝消息
	 * @param m
	 * @return
	 */
	public Message cloneMessage(Message m);
	
	/**
	 * 修改消息下次执行状态
	 * @param m
	 * @return
	 */
	public Message updateNextExecute(Message m ,int nextTime);
	
	/**
	 * 由json生成消息
	 * @param json
	 * @return
	 */
	public Message genMessage(String category , int receiveTime ,Map<String,String> content) throws Exception;
}
